57ad943502103a60cc415081574c0efa37fab39e,graylog2-server/src/main/java/org/graylog2/buffers/ProcessBuffer.java,ProcessBuffer,initialize,#,73
Before Change
Disruptor<MessageEvent> disruptor = new Disruptor<MessageEvent>(
MessageEvent.EVENT_FACTORY,
executor,
new MultiThreadedClaimStrategy(server.getConfiguration().getRingSize()),
server.getConfiguration().getProcessorWaitStrategy()
);
After Change
public void initialize() {
Disruptor disruptor = new Disruptor<MessageEvent>(
MessageEvent.EVENT_FACTORY,
server.getConfiguration().getRingSize(),
executor,
ProducerType.MULTI,
server.getConfiguration().getProcessorWaitStrategy()